// 版权所有2009 Go作者。版权所有。
// 此源代码的使用受BSD样式
// 许可证的约束，该许可证可以在许可证文件中找到。

// HTTP客户端。参见RFC 7230至7235。
// 
// 这是高级客户端接口。
// 底层实现在transport.go中。

package http

import (
	"context"
	"crypto/tls"
	"encoding/base64"
	"errors"
	"fmt"
	"io"
	"log"
	"net/http/internal/ascii"
	"net/url"
	"reflect"
	"sort"
	"strings"
	"sync"
	"time"
)

// 客户端是HTTP客户端。它的零值（DefaultClient）是一个
// 使用DefaultTransport的可用客户端。
// 
// 客户端的传输通常具有内部状态（缓存的TCP 
// 连接），因此应该重用客户端，而不是根据需要创建
// 客户端。多个goroutine并发使用客户端是安全的。
// 
// 客户端的级别高于往返程序（如传输）
// 并额外处理HTTP详细信息，如cookies和
// 重定向。
// 
// 当执行以下重定向时，客户端将转发所有在
// 上设置的头，除了：
// 
// /•当转发敏感头（如“授权”、“
// “WWW-Authenticate”和“Cookie”）到不受信任的目标时。
// 重定向到域
// 该域与初始域不匹配或不完全匹配时，将忽略这些标头。
// 例如，从“foo.com”重定向到“foo.com”或“sub.foo.com”将转发敏感头，但重定向到“bar.com”则不会。
// 
// /•使用非零Cookie Jar转发“Cookie”标头时。
// 由于每个重定向可能会改变cookie jar的状态，
// 重定向可能会改变初始请求中的cookie集。
// 转发“Cookie”头时，将忽略任何变异Cookie，
// 期望Jar将插入那些变异Cookie 
// 以及更新的值（假设源匹配）。
// 如果Jar为nil，则初始cookie将被转发而不做任何更改。
// 
type Client struct {
	// 传输指定发出单个
	// HTTP请求的机制。
	// 如果为零，则使用DefaultTransport。
	Transport RoundTripper

	// CheckRedirect指定处理重定向的策略。
	// 如果CheckRedirect不是nil，则客户端在HTTP重定向之后在
	// 之前调用它。req和via参数是
	// 即将发出的请求和已经发出的请求，最早的
	// 首先。如果CheckRedirect返回错误，则客户端的Get-
	// 方法将返回上一个响应（其主体
	// 已关闭）和CheckRedirect的错误（包装在url.error中）
	// 而不是发出请求req。
	// 作为一种特殊情况，如果CheckRedirect返回ErrUseLastResponse，
	// 则返回最近的响应及其主体
	// 未关闭，同时返回一个零错误。
	// 
	// 如果CheckRedirect为零，则客户端使用其默认策略
	// 在连续10个请求后停止。
	CheckRedirect func(req *Request, via []*Request) error

	// Jar指定cookie Jar。
	// 
	// Jar用于将相关cookie插入每个
	// 出站请求，并使用每个入站响应的cookie值
	// 进行更新。客户机遵循的每个
	// 重定向都会参考Jar。
	// 
	// 如果Jar为零，则仅当cookie在请求中显式设置为
	// 时，才会发送cookie。
	Jar CookieJar

	// 超时指定此
	// 客户端发出的请求的时间限制。超时包括连接时间、任何
	// 重定向和读取响应正文。在Get、Head、Post或Do返回后，计时器将保持运行，并将中断Response.Body的读取。
	// 
	// 超时为零表示没有超时。
	// 
	// 客户端取消对底层传输的请求
	// 就像请求的上下文结束一样。
	// 
	// 为了兼容性，客户端还将在传输上使用不推荐的
	// CancelRequest方法（如果找到）。新的
	// 往返程序实现应使用请求的上下文
	// 进行取消，而不是实现CancelRequest。
	Timeout time.Duration
}

// DefaultClient是默认客户端，由Get、Head和Post使用。
var DefaultClient = &Client{}

// RoundTripper是一个接口，表示执行
// 单个HTTP事务，获取给定请求的响应的能力。
// 
// 多个
// goroutine同时使用往返程序必须是安全的。
type RoundTripper interface {
	// 往返执行单个HTTP事务，返回
	// 对所提供请求的响应。
	// 
	// 往返不应尝试解释响应。特别是在
	// 中，如果获得了
	// 响应，往返必须返回err==nil，而不管响应的HTTP状态代码如何。
	// 如果无法获得
	// 响应，则应保留非零错误。同样，往返不应试图处理更高级别的协议细节，如重定向、身份验证或cookie。
	// 
	// 往返不应修改请求，但
	// 使用并关闭请求正文除外。往返可能
	// 在单独的goroutine中读取请求的字段。调用方
	// 在关闭响应的
	// 正文之前，不应变异或重用请求。
	// 
	// 往返必须始终关闭正文，包括在出现错误时，
	// 但根据实现情况，可能会在单独的
	// GOROUTE中关闭正文，即使在往返返回后也是如此。这意味着要在后续请求中重用正文的调用方必须安排在执行此操作之前等待关闭调用。
	// 
	// 请求的URL和头字段必须初始化。
	RoundTrip(*Request) (*Response, error)
}

// refererForURL返回一个没有任何身份验证信息的referer，或者如果lastReq方案是https而newReq方案是http，则返回一个空字符串。
func refererForURL(lastReq, newReq *url.URL) string {
	// https:
	// “如果引用页面是通过安全协议传输的，则客户端不应在
	// （非安全）HTTP请求中包含引用者标头字段。”
	if lastReq.Scheme == "https" && newReq.Scheme == "http" {
		return ""
	}
	referer := lastReq.String()
	if lastReq.User != nil {
		// ，但这是我们能做的最好的事情了：
		// -在URL上引入新方法
		// -创建竞争条件
		// -手动复制URL结构，这将导致
		// 线路下的维护问题
		auth := lastReq.User.String() + "@"
		referer = strings.Replace(referer, auth, "", 1)
	}
	return referer
}

// 只有在错误！=无
func (c *Client) send(req *Request, deadline time.Time) (resp *Response, didTimeout func() bool, err error) {
	if c.Jar != nil {
		for _, cookie := range c.Jar.Cookies(req.URL) {
			req.AddCookie(cookie)
		}
	}
	resp, didTimeout, err = send(req, c.transport(), deadline)
	if err != nil {
		return nil, didTimeout, err
	}
	if c.Jar != nil {
		if rc := resp.Cookies(); len(rc) > 0 {
			c.Jar.SetCookies(req.URL, rc)
		}
	}
	return resp, nil, nil
}

func (c *Client) deadline() time.Time {
	if c.Timeout > 0 {
		return time.Now().Add(c.Timeout)
	}
	return time.Time{}
}

func (c *Client) transport() RoundTripper {
	if c.Transport != nil {
		return c.Transport
	}
	return DefaultTransport
}

// 发送发出HTTP请求。
// 调用方在完成读取后应关闭相应的正文。
func send(ireq *Request, rt RoundTripper, deadline time.Time) (resp *Response, didTimeout func() bool, err error) {
	req := ireq // req要么是原始请求，要么是修改后的fork 

	if rt == nil {
		req.closeBody()
		return nil, alwaysFalse, errors.New("http: no Client.Transport or DefaultTransport")
	}

	if req.URL == nil {
		req.closeBody()
		return nil, alwaysFalse, errors.New("http: nil Request.URL")
	}

	if req.RequestURI != "" {
		req.closeBody()
		return nil, alwaysFalse, errors.New("http: Request.RequestURI can't be set in client requests")
	}

	// fork req将req分叉到ireq的浅克隆中第一次调用它时。
	forkReq := func() {
		if ireq == req {
			req = new(Request)
			*req = *ireq // 浅克隆
		}
	}

	// 大多数send（Get、Post等）的调用方不需要
	// 头，使其处于未初始化状态。但是，我们向
	// 传输保证，这已经初始化。
	if req.Header == nil {
		forkReq()
		req.Header = make(Header)
	}

	if u := req.URL.User; u != nil && req.Header.Get("Authorization") == "" {
		username := u.Username()
		password, _ := u.Password()
		forkReq()
		req.Header = cloneOrMakeHeader(ireq.Header)
		req.Header.Set("Authorization", "Basic "+basicAuth(username, password))
	}

	if !deadline.IsZero() {
		forkReq()
	}
	stopTimer, didTimeout := setRequestCancel(req, rt, deadline)

	resp, err = rt.RoundTrip(req)
	if err != nil {
		stopTimer()
		if resp != nil {
			log.Printf("RoundTripper returned a response & error; ignoring response")
		}
		if tlsErr, ok := err.(tls.RecordHeaderError); ok {
			// 如果我们得到一个错误的TLS记录头，请检查
			// 响应是否类似于HTTP，并给出一个更有用的错误。
			// 见golang.org/issue/11111。
			if string(tlsErr.RecordHeader[:]) == "HTTP/" {
				err = errors.New("http: server gave HTTP response to HTTPS client")
			}
		}
		return nil, didTimeout, err
	}
	if resp == nil {
		return nil, didTimeout, fmt.Errorf("http: RoundTripper implementation (%T) returned a nil *Response with a nil error", rt)
	}
	if resp.Body == nil {
		// Body字段上的文档说明“http客户端和传输
		// 保证Body始终为非零，即使在没有Body的响应或具有零长度Body的响应上也是如此。”不幸的是，我们没有为任意RoundTripper实现记录相同的约束条件，而野生环境中的RoundTripper实现（大部分在测试中）假设
		// 它们可以使用nil Body来表示空的（类似于Request.Body）。
		// （请参阅https:
		// 
		// 如果ContentLength允许正文为空，请在此处填写一个空的
		// 以确保它不为零。
		if resp.ContentLength > 0 && req.Method != "HEAD" {
			return nil, didTimeout, fmt.Errorf("http: RoundTripper implementation (%T) returned a *Response with content length %d but a nil Body", rt, resp.ContentLength)
		}
		resp.Body = io.NopCloser(strings.NewReader(""))
	}
	if !deadline.IsZero() {
		resp.Body = &cancelTimerBody{
			stop:          stopTimer,
			rc:            resp.Body,
			reqDidTimeout: didTimeout,
		}
	}
	return resp, nil, nil
}

// timeBeforeContextDeadline报告非零时间t在ctx的截止日期之前是否为
// 如果有。如果ctx没有死机不，它总是报告true（最后期限被认为是无限的）。
func timeBeforeContextDeadline(t time.Time, ctx context.Context) bool {
	d, ok := ctx.Deadline()
	if !ok {
		return true
	}
	return t.Before(d)
}

// knownRoundTripperImpl报告rt是否是由Go团队维护的往返程序，并且已知实现了最新的
// 可选语义（特别是上下文）。该请求用于检查此特定请求是否使用了备用协议，在这种情况下，我们需要检查该协议的往返程序。
// 这有一个很小的误报机会。
func knownRoundTripperImpl(rt RoundTripper, req *Request) bool {
	switch t := rt.(type) {
	case *Transport:
		if altRT := t.alternateRoundTripper(req); altRT != nil {
			return knownRoundTripperImpl(altRT, req)
		}
		return true
	case *http2Transport, http2noDialH2RoundTripper:
		return true
	}
	// 与其检测我们的golang.org/x/net/http2.Transport，不如检测另一个http2 
	// 包中的传输类型。但是我什么都不知道，唯一的问题是如果传输不支持上下文，一些临时泄漏的goroutine就会出现问题。所以这是一个很好的启发：
	if reflect.TypeOf(rt).String() == "*http2.Transport" {
		return true
	}
	return false
}

// setRequestCancel设置req.Cancel，并在deadline为非零时向req添加一个deadline上下文。RoundTripper的类型用于
// 确定是否应使用传统的CancelRequest行为。
// 
// 作为后台，取消请求有三种方式：
// 首先是Transport.CancelRequest。（已弃用）
// 第二个是请求。取消。
// 第三个是Request.Context。
// 此函数填充第二个和第三个，如果确实需要，则使用第一个。
func setRequestCancel(req *Request, rt RoundTripper, deadline time.Time) (stopTimer func(), didTimeout func() bool) {
	if deadline.IsZero() {
		return nop, alwaysFalse
	}
	knownTransport := knownRoundTripperImpl(rt, req)
	oldCtx := req.Context()

	if req.Cancel == nil && knownTransport {
		// 如果他们已经有一个请求。上下文是
		// 即将过期，什么也不做：
		if !timeBeforeContextDeadline(deadline, oldCtx) {
			return nop, alwaysFalse
		}

		var cancelCtx func()
		req.ctx, cancelCtx = context.WithDeadline(oldCtx, deadline)
		return cancelCtx, func() bool { return time.Now().After(deadline) }
	}
	initialReqCancel := req.Cancel // 用户的原始请求。取消，如果有

	var cancelCtx func()
	if oldCtx := req.Context(); timeBeforeContextDeadline(deadline, oldCtx) {
		req.ctx, cancelCtx = context.WithDeadline(oldCtx, deadline)
	}

	cancel := make(chan struct{})
	req.Cancel = cancel

	doCancel := func() {
		// 上述函数注释中的第二种方式：
		close(cancel)
		// 第一种方式，仅用于Go 1.5或Go 1.6之前编写的往返程序
		// 实现。
		type canceler interface{ CancelRequest(*Request) }
		if v, ok := rt.(canceler); ok {
			v.CancelRequest(req)
		}
	}

	stopTimerCh := make(chan struct{})
	var once sync.Once
	stopTimer = func() {
		once.Do(func() {
			close(stopTimerCh)
			if cancelCtx != nil {
				cancelCtx()
			}
		})
	}

	timer := time.NewTimer(time.Until(deadline))
	var timedOut atomicBool

	go func() {
		select {
		case <-initialReqCancel:
			doCancel()
			timer.Stop()
		case <-timer.C:
			timedOut.setTrue()
			doCancel()
		case <-stopTimerCh:
			timer.Stop()
		}
	}()

	return stopTimer, timedOut.isSet
}

// 见第2页（第4页末尾）https:
// “要接收授权，客户端将发送用户ID和密码
// 在凭据中的base64 
// 编码字符串中，以单个冒号（：）分隔。”
// 它不应该被URL编码。
func basicAuth(username, password string) string {
	auth := username + ":" + password
	return base64.StdEncoding.EncodeToString([]byte(auth))
}

// Get发出对指定URL的获取。如果响应是
// 以下重定向代码之一，Get将遵循重定向，最多可达
// 最多10个重定向：
// 
// 301（永久移动）
// 308（永久重定向）
// 
// 如果重定向太多或
// 是HTTP协议错误，则返回错误。非2xx响应不会导致
// 错误。任何返回的错误都将是*url.error类型。如果请求超时，url.Error 
// 值的Timeout方法将报告true。
// 
// 当err为nil时，resp始终包含非nil resp.Body。
// 调用方在完成读取后应关闭相应的正文。
// 
// Get是DefaultClient.Get的包装器。
// 
// 若要使用自定义标头发出请求，请使用NewRequest和
// DefaultClient.Do。
// 
// 若要使用指定的上下文进行请求。上下文，请使用NewRequestWithContext 
// 和DefaultClient.Do。
func Get(url string) (resp *Response, err error) {
	return DefaultClient.Get(url)
}

// Get发出对指定URL的获取。如果响应是
// 以下重定向代码之一，则Get在调用
// 客户端的CheckRedirect函数后遵循重定向：
// 
// 301（永久移动）
// 302（找到）
// 303（参见其他）
// 307（临时重定向）
// 308（永久重定向）
// 
// 如果客户端的CheckRedirect函数失败或存在HTTP协议错误，则返回错误。非2xx响应不会导致错误。任何返回的错误类型都将为*url.error。
// url.error值的超时方法将报告true如果请求
// 超时。
// 
// 当err为零时，resp始终包含一个非零的resp.Body。
// 调用方在读取resp.Body时应关闭resp.Body。
// 
// 若要使用自定义标头发出请求，请使用NewRequest和Client.Do.
// 
// 若要使用指定的上下文发出请求。上下文，请使用NewRequestWithContext 
// 和Client.Do.
func (c *Client) Get(url string) (resp *Response, err error) {
	req, err := NewRequest("GET", url, nil)
	if err != nil {
		return nil, err
	}
	return c.Do(req)
}

func alwaysFalse() bool { return false }

// 客户端可以返回ErrUseLastResponse。CheckRedirect钩子指向
// 控制重定向的处理方式。如果返回，则不会发送下一个请求
// 并且返回的最新响应的正文为
// 未关闭。
var ErrUseLastResponse = errors.New("net/http: use last response")

// checkRedirect调用用户配置的checkRedirect 
// 函数或默认值。
func (c *Client) checkRedirect(req *Request, via []*Request) error {
	fn := c.CheckRedirect
	if fn == nil {
		fn = defaultCheckRedirect
	}
	return fn(req, via)
}

// REDIRECT行为描述了当
// 客户端遇到来自服务器
func redirectBehavior(reqMethod string, resp *Response, ireq *Request) (redirectMethod string, shouldRedirect, includeBody bool) {
	switch resp.StatusCode {
	case 301, 302, 303:
		redirectMethod = reqMethod
		shouldRedirect = true
		includeBody = false

		// RFC 2616仅允许使用GET和
		// 头请求。RFC 7231取消了这个限制，但我们仍然限制其他方法来保持兼容性。
		// 见第18570期。
		if reqMethod != "GET" && reqMethod != "HEAD" {
			redirectMethod = "GET"
		}
	case 307, 308:
		redirectMethod = reqMethod
		shouldRedirect = true
		includeBody = true

		// 特别对待307和308，因为它们在
		// Go 1.8中是新的，并且它们还需要重新发送请求正文。
		if resp.Header.Get("Location") == "" {
			// 308s已在野生环境中观察到，正在食用
			// ，无位置标题。由于Go 1.7和早期版本
			// 没有遵循这些代码，因此请停止此处，而不是返回错误。
			// 见第17773期。
			shouldRedirect = false
			break
		}
		if ireq.GetBody == nil && ireq.outgoingLength() != 0 {
			// 我们有一个请求主体，307/308要求
			// 重新发送，但未定义GetBody。因此，只需将此响应返回给用户，而不是像Go 1.7和更早版本那样返回错误。
			shouldRedirect = false
		}
	}
	return redirectMethod, shouldRedirect, includeBody
}

// URLRERROOP返回要用于
// 提供的（*Request）.Method值的（*url.Error）.Op值。
func urlErrorOp(method string) string {
	if method == "" {
		return "Get"
	}
	if lowerMethod, ok := ascii.ToLower(method); ok {
		return method[:1] + lowerMethod[1:]
	}
	return method
}

// Do发送HTTP请求并返回HTTP响应，遵循
// 客户端上配置的策略（如重定向、cookie、身份验证）。
// 
// 如果是由于客户端策略（如
// CheckRedirect）或无法使用HTTP（如网络
// 连接问题）导致，则返回错误。非2xx状态代码不会导致
// 错误。
// 
// 如果返回的错误为零，则响应将包含一个非零的
// 正文，用户应关闭该正文。如果正文不是同时读取EOF和关闭，则客户端的底层往返程序
// （通常为传输）可能无法重新使用到服务器的持久TCP 
// 连接，以进行后续的“保持活动”请求。
// 
// 如果请求正文非空，则将由基础
// 传输关闭，即使出现错误也是如此。
// 
// 出现错误时，可以忽略任何响应。带有
// 非nil错误的非nil响应仅在CheckRedirect失败时才会发生，即使如此，
// 返回的响应。正文已关闭。
// 
// 通常使用Get、Post或PostForm代替Do。
// 
// 如果服务器回复重定向，则客户端首先使用
// CheckRedirect函数确定是否应遵循重定向。如果允许，301、302或303重定向会导致后续请求使用HTTP方法GET 
// （如果原始请求为HEAD，则为HEAD），而没有正文。
// 如果定义了Request.GetBody函数，307或308重定向将保留原始HTTP方法和正文，
// 则保留原始HTTP方法和正文。
// NewRequest函数自动为常用
// 标准库正文类型设置GetBody。
// 
// 任何返回的错误类型都将是*url.error。如果请求超时，url.Error 
// 值的Timeout方法将报告true。
func (c *Client) Do(req *Request) (*Response, error) {
	return c.do(req)
}

var testHookClientDoResult func(retres *Response, reterr error)

func (c *Client) do(req *Request) (retres *Response, reterr error) {
	if testHookClientDoResult != nil {
		defer func() { testHookClientDoResult(retres, reterr) }()
	}
	if req.URL == nil {
		req.closeBody()
		return nil, &url.Error{
			Op:  urlErrorOp(req.Method),
			Err: errors.New("http: nil Request.URL"),
		}
	}

	var (
		deadline      = c.deadline()
		reqs          []*Request
		resp          *Response
		copyHeaders   = c.makeHeadersCopier(req)
		reqBodyClosed = false // 我们是否关闭了当前的请求正文？

		// 重定向行为：
		redirectMethod string
		includeBody    bool
	)
	uerr := func(err error) error {
		// 主体可能已被c关闭。send（）
		if !reqBodyClosed {
			req.closeBody()
		}
		var urlStr string
		if resp != nil && resp.Request != nil {
			urlStr = stripPassword(resp.Request.URL)
		} else {
			urlStr = stripPassword(req.URL)
		}
		return &url.Error{
			Op:  urlErrorOp(reqs[0].Method),
			URL: urlStr,
			Err: err,
		}
	}
	for {
		// 对于除第一个请求以外的所有请求，创建下一个
		// 请求跃点和替换请求。
		if len(reqs) > 0 {
			loc := resp.Header.Get("Location")
			if loc == "" {
				resp.closeBody()
				return nil, uerr(fmt.Errorf("%d response missing Location header", resp.StatusCode))
			}
			u, err := req.URL.Parse(loc)
			if err != nil {
				resp.closeBody()
				return nil, uerr(fmt.Errorf("failed to parse Location header %q: %v", loc, err))
			}
			host := ""
			if req.Host != "" && req.Host != req.URL.Host {
				// 如果调用方指定了自定义主机头，并且
				// 重定向位置是相对的，则通过重定向保留主机头
				// 。见第22233期。
				if u, _ := url.Parse(loc); u != nil && !u.IsAbs() {
					host = req.Host
				}
			}
			ireq := reqs[0]
			req = &Request{
				Method:   redirectMethod,
				Response: resp,
				URL:      u,
				Header:   make(Header),
				Host:     host,
				Cancel:   ireq.Cancel,
				ctx:      ireq.ctx,
			}
			if includeBody && ireq.GetBody != nil {
				req.Body, err = ireq.GetBody()
				if err != nil {
					resp.closeBody()
					return nil, uerr(err)
				}
				req.ContentLength = ireq.ContentLength
			}

			// 在设置Referer之前复制原始标题，
			// 如果用户在第一次请求时设置了Referer。
			// 如果他们真的想覆盖，他们可以在
			// 他们的CheckRedirect函数中完成。
			copyHeaders(req)

			// 将最新的
			// 请求URL中的Referer头添加到新的URL中，如果不是https->http:
			if ref := refererForURL(reqs[len(reqs)-1].URL, req.URL); ref != "" {
				req.Header.Set("Referer", ref)
			}
			err = c.checkRedirect(req, reqs)

			// 哨兵错误，则允许用户选择
			// 以前的响应，而不关闭其
			// 正文。见第10069期。
			if err == ErrUseLastResponse {
				return resp, nil
			}

			// 关闭上一个响应的主体。但是，至少读取部分正文，如果是小的，则底层TCP连接将被重复使用。无需检查错误：如果
			// 失败，传输将不会重新使用它。
			const maxBodySlurpSize = 2 << 10
			if resp.ContentLength == -1 || resp.ContentLength <= maxBodySlurpSize {
				io.CopyN(io.Discard, resp.Body, maxBodySlurpSize)
			}
			resp.Body.Close()

			if err != nil {
				// Go 1兼容性的特殊情况：如果CheckRedirect函数失败，则返回响应
				// 和错误。
				// 请参见https:
				// 相应的正文已关闭。
				ue := uerr(err)
				ue.(*url.Error).URL = loc
				return resp, ue
			}
		}

		reqs = append(reqs, req)
		var err error
		var didTimeout func() bool
		if resp, didTimeout, err = c.send(req, deadline); err != nil {
			// c.send（）始终关闭请求体
			reqBodyClosed = true
			if !deadline.IsZero() && didTimeout() {
				err = &httpError{
					err:     err.Error() + " (Client.Timeout exceeded while awaiting headers)",
					timeout: true,
				}
			}
			return nil, uerr(err)
		}

		var shouldRedirect bool
		redirectMethod, shouldRedirect, includeBody = redirectBehavior(req.Method, resp, reqs[0])
		if !shouldRedirect {
			return resp, nil
		}

		req.closeBody()
	}
}

// makeHeadersCopier生成一个函数，从
// 初始请求ireq复制头。对于每个重定向，必须调用此函数
// 以便它可以将头复制到即将到来的请求中。
func (c *Client) makeHeadersCopier(ireq *Request) func(*Request) {
	// 要复制的头来自最初的请求。
	// 我们使用closured回调来保留对这些原始头的引用。
	var (
		ireqhdr  = cloneOrMakeHeader(ireq.Header)
		icookies map[string][]*Cookie
	)
	if c.Jar != nil && ireq.Header.Get("Cookie") != "" {
		icookies = make(map[string][]*Cookie)
		for _, c := range ireq.Cookies() {
			icookies[c.Name] = append(icookies[c.Name], c)
		}
	}

	preq := ireq // 上一个请求
	return func(req *Request) {
		// 如果存在Jar，并且通过请求头提供了一些初始cookie 
		// ，然后，我们可能需要在跟踪重定向时更改初始的
		// cookies，因为每个重定向都可能最终导致
		// 修改预先存在的cookie。
		// 
		// 由于已在请求头中设置的cookie不包含关于原始域和路径的信息，因此
		// 下面的逻辑假定任何新设置的cookie都会覆盖原始cookie 
		// 而不管域或路径如何。
		// 
		// 请参阅https:
		if c.Jar != nil && icookies != nil {
			var changed bool
			resp := req.Response // 导致即将发生的重定向的响应
			for _, c := range resp.Cookies() {
				if _, ok := icookies[c.Name]; ok {
					delete(icookies, c.Name)
					changed = true
				}
			}
			if changed {
				ireqhdr.Del("Cookie")
				var ss []string
				for _, cs := range icookies {
					for _, c := range cs {
						ss = append(ss, c.Name+"="+c.Value)
					}
				}
				sort.Strings(ss) // 确保确定性标头
				ireqhdr.Set("Cookie", strings.Join(ss, "; "))
			}
		}

		// 复制初始请求的标头值
		// （至少是安全的）。
		for k, vv := range ireqhdr {
			if shouldCopyHeaderOnRedirect(k, preq.URL, req.URL) {
				req.Header[k] = vv
			}
		}

		preq = req // 使用当前请求更新以前的请求
	}
}

func defaultCheckRedirect(req *Request, via []*Request) error {
	if len(via) >= 10 {
		return errors.New("stopped after 10 redirects")
	}
	return nil
}

// Post向指定的URL发出Post。
// 
// 调用方在完成读取后应关闭相应的正文。
// 
// 如果提供的主体是io.Closer，则在
// 请求后关闭。
// 
// Post是DefaultClient.Post的包装器。
// 
// 要设置自定义头，请使用NewRequest和DefaultClient.Do。
// 
// 请参阅客户端。有关如何处理重定向
// 的详细信息，请参阅方法文档。
// 
// 若要使用指定的上下文进行请求。上下文，请使用NewRequestWithContext 
// 和DefaultClient.Do。
func Post(url, contentType string, body io.Reader) (resp *Response, err error) {
	return DefaultClient.Post(url, contentType, body)
}

// Post向指定的URL发出Post。
// 
// 调用方在完成读取后应关闭相应的正文。
// 
// 如果提供的主体是io.Closer，则在
// 请求后关闭。
// 
// 要设置自定义头，请使用NewRequest和Client.Do。
// 
// 若要使用指定的上下文发出请求。上下文，请使用NewRequestWithContext 
// 和Client.Do。
// 
// 请参阅客户端。有关如何处理重定向
// 的详细信息，请参阅方法文档。
func (c *Client) Post(url, contentType string, body io.Reader) (resp *Response, err error) {
	req, err := NewRequest("POST", url, body)
	if err != nil {
		return nil, err
	}
	req.Header.Set("Content-Type", contentType)
	return c.Do(req)
}

// PostForm向指定的URL发出POST，数据的键和值URL编码为请求体。
// 
// 内容类型头设置为application/x-www-form-urlencoded。
// 要设置其他头，请使用NewRequest和DefaultClient.Do。
// 
// 当err为nil时，resp始终包含非nil resp.Body。
// 调用方在完成读取后应关闭相应的正文。
// 
// PostForm是DefaultClient.PostForm的包装器。
// 
// 请参阅客户端。有关如何处理重定向
// 的详细信息，请参阅方法文档。
// 
// 要使用指定的上下文发出请求。上下文，请使用NewRequestWithContext 
// 和DefaultClient.Do。
func PostForm(url string, data url.Values) (resp *Response, err error) {
	return DefaultClient.PostForm(url, data)
}

// PostForm向指定的URL发出POST，
// 将数据的键和值URL编码为请求主体。
// 
// 内容类型头设置为application/x-www-form-urlencoded。
// 要设置其他头，请使用NewRequest和Client.Do。
// 
// 当err为nil时，resp始终包含非nil resp.Body。
// 调用方在完成读取后应关闭相应的正文。
// 
// 请参阅客户端。有关如何处理重定向
// 的详细信息，请参阅方法文档。
// 
// 若要使用指定的上下文发出请求。上下文，请使用NewRequestWithContext 
// 和Client.Do。
func (c *Client) PostForm(url string, data url.Values) (resp *Response, err error) {
	return c.Post(url, "application/x-www-form-urlencoded", strings.NewReader(data.Encode()))
}

// Head向指定的URL发出一个Head。如果响应是
// 以下重定向代码之一，则Head将遵循重定向，最多为
// 最多10个重定向：
// 
// 301（永久移动）
// 302（找到）
// 303（参见其他）
// 307（临时重定向）
// 308（永久重定向）
// 
// Head是DefaultClient的包装器。Head 
// 
// 要使用指定的上下文发出请求。上下文，请使用NewRequestWithContext 
// 和DefaultClient.Do。
func Head(url string) (resp *Response, err error) {
	return DefaultClient.Head(url)
}

// Head向指定的URL发出一个Head。如果响应是
// 以下重定向代码之一，则Head在调用
// 客户端的CheckRedirect函数后遵循重定向：
// 
// 301（永久移动）
// 302（找到）
// 303（参见其他）
// 307（临时重定向）
// 308（永久重定向）
// 
// 若要使用指定的上下文发出请求。上下文，请使用NewRequestWithContext 
// 和Client.Do.
func (c *Client) Head(url string) (resp *Response, err error) {
	req, err := NewRequest("HEAD", url, nil)
	if err != nil {
		return nil, err
	}
	return c.Do(req)
}

// CloseIdleConnections关闭其传输上的所有连接，这些连接以前是从以前的请求连接的，但现在是
// 的在“保持活力”中无所事事状态。它不会中断当前使用的任何连接。
// 
// 
// 如果客户端的传输没有CloseIdReconnections方法
// 则此方法不执行任何操作。
func (c *Client) CloseIdleConnections() {
	type closeIdler interface {
		CloseIdleConnections()
	}
	if tr, ok := c.transport().(closeIdler); ok {
		tr.CloseIdleConnections()
	}
}

// cancelTimerBody是一个io.ReadCloser，它使用两个特性包装rc：
// 1）读取错误或关闭时，调用停止函数。
// 2）在读取失败时，如果reqDidTimeout为true，则会包装错误并将
// 标记为命中其超时的net.error。
type cancelTimerBody struct {
	stop          func() // 停止时间。等待取消请求的计时器
	rc            io.ReadCloser
	reqDidTimeout func() bool
}

func (b *cancelTimerBody) Read(p []byte) (n int, err error) {
	n, err = b.rc.Read(p)
	if err == nil {
		return n, nil
	}
	b.stop()
	if err == io.EOF {
		return n, err
	}
	if b.reqDidTimeout() {
		err = &httpError{
			err:     err.Error() + " (Client.Timeout or context cancellation while reading body)",
			timeout: true,
		}
	}
	return n, err
}

func (b *cancelTimerBody) Close() error {
	err := b.rc.Close()
	b.stop()
	return err
}

func shouldCopyHeaderOnRedirect(headerKey string, initial, dest *url.URL) bool {
	switch CanonicalHeaderKey(headerKey) {
	case "Authorization", "Www-Authenticate", "Cookie", "Cookie2":
		// 允许将auth/cookie头从“foo.com”
		// 发送到“sub.foo.com”。

		// 请注意，我们不会自动将所有cookie发送到子域
		// 。此函数仅用于在初始传出
		// Cookies。通过
		// 客户端请求上显式设置的
		// CookieJar机制自动添加的cookie将继续跟随每个
		// cookie的作用域，如set cookie设置的那样。但是对于Cookie头直接设置为
		// 的传出请求，我们不知道它们的范围，因此我们假设
		// 是针对*.domain.com的。

		ihost := canonicalAddr(initial)
		dhost := canonicalAddr(dest)
		return isDomainOrSubdomain(dhost, ihost)
	}
	// 复制所有其他头：
	return true
}

// isDomainOrSubdomain报告sub是否为父域的子域（或确切的
// 匹配）。
// 
// 这两个域必须已经是规范格式。
func isDomainOrSubdomain(sub, parent string) bool {
	if sub == parent {
		return true
	}
	// 如果sub为“foo.example.com”，父项为“example.com”，则
	// 这意味着sub必须以“.”+父项结尾。
	// 不用分配就可以完成。
	if !strings.HasSuffix(sub, parent) {
		return false
	}
	return sub[len(sub)-len(parent)-1] == '.'
}

func stripPassword(u *url.URL) string {
	_, passSet := u.User.Password()
	if passSet {
		return strings.Replace(u.String(), u.User.String()+"@", u.User.Username()+":***@", 1)
	}
	return u.String()
}
